var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function (err, conn) {
    conn.createChannel(function (err, ch) {
        var q = 'task_queue';

        ch.assertQueue(q, { durable: false });

        console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
        ch.consume(q, function (msg) {
            
            var secs = msg.content.toString().split('.').length -1;
            
            console.log(" [*] Received %s", msg.content.toString());

            setTimeout(() => {
                console.log(" [*] Done");
            }, secs * 1000);
        }, { noAck: true });
    })
})